package net.mingsoft.report_data.biz;

import net.mingsoft.report_data.kafka.avro.ZkReport;

import java.util.List;

/**
 * Kafka消息服务
 * @author gengfa
 * @date 22/03/28
 */
public interface ZkDataMessageBiz {

    /**
     * 保存Kafka消息
     * @param message 消息
     * @return 保存结果
     */
    boolean saveMessage(ZkReport message);

    /**
     * 解析消息
     */
    void parseMessage();

    void parseMessage(List<String> types);
}
